#include "aio_callback_thread.h"
#include "../global/head.h"
#include "../xos/head.h"
#include "../buf/head.h"
#include "aio_impl.h"

/////////////////////////////////////////////////////////////////////////////////////////
// 
namespace xos
{
    aio_callback_thread::aio_callback_thread( aio_impl * pAioImpl ) : m_pAioImpl( pAioImpl )
    {
    }

    aio_callback_thread::~aio_callback_thread()
    {
    }

    ////////////////////////////////////////////////////////////////////////////////////
    // 

    int aio_callback_thread::notify( msg_impl * p )
    {
        int nRet = 0;

        p->set_runnable( 0, m_pAioImpl->m_pCallback );
        m_pAioImpl->m_pCallbackObj->notify( p );

        return nRet;
    }

    int aio_callback_thread::init()
    {
        int nRet = 0;
        return nRet;
    }

    int aio_callback_thread::term()
    {
        int nRet = 0;
        return nRet;
    }

    ////////////////////////////////////////////////////////////////////////////////////
    // 

} // xos
